package com.songjia.stream.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.SubscribableChannel;

/**
 * 
 * 
 * @Description: 自定义接口
 *
 * @author: songjia
 * @date: 2018年3月27日 下午3:36:12
 */
public interface SendToBinder {

	String INPUT = "sendtoInput";

	String OUTPUT = "sendtoOutput";

	/**
	 * 创建名为 “sendtoOutput” 的输出通道
	 * 
	 * @return
	 */
	@Output(OUTPUT)
	SubscribableChannel output();

	/**
	 * 创建名为 “sendtoInput” 的输入通道
	 * 
	 * @return
	 */
	@Input(INPUT)
	SubscribableChannel input();
}
